package cn.cutie.clot.mq.server;

import lombok.AllArgsConstructor;
import lombok.Data;

/**
 * @Description: 订阅关系
 * @Author: Cutie
 * @CreateDate: 2024/7/10 10:39
 * @Version: 0.0.1
 */
@Data
@AllArgsConstructor
public class MessageSubscription {
    private String topic;
    private String consumerId;
    // 消费到哪个位置
    private int offset = -1;
}
